RocketMQ (十一) 消费者 |
您所在的位置:网站首页 › rocketmq 创建消费者 › RocketMQ (十一) 消费者 |
目录
1、消费者(Consumer)2、模型关系3、内部属性3.1 消费者分组名称3.2 客户端ID3.3 通信参数3.4 预绑定订阅关系列表3.5 消费监听器
4、使用建议
1、消费者(Consumer)
消费者是 Apache RocketMQ 中用来接收并处理消息的运行实体。 消费者通常被集成在业务系统中,从 Apache RocketMQ 服务端获取消息,并将消息转化成业务可理解的信息,供业务逻辑处理。 在消息消费端,可以定义如下传输行为: 消费者身份:消费者必须关联一个指定的消费者分组,以获取分组内统一定义的行为配置和消费状态。消费者类型:Apache RocketMQ面向不同的开发场景提供了多样的消费者类型,包括PushConsumer类型、SimpleConsumer类型、PullConsumer类型(仅推荐流处理场景使用)等。具体信息,请参见消费者分类。消费者本地运行配置:消费者根据不同的消费者类型,控制消费者客户端本地的运行配置。例如消费者客户端的线程数,消费并发度等,实现不同的传输效果。 2、模型关系不建议单一进程创建大量消费者 Apache RocketMQ 的消费者在通信协议层面支持非阻塞传输模式,网络通信效率较高,并且支持多线程并发访问。因此,大部分场景下,单一进程内同一个消费分组只需要初始化唯一的一个消费者即可,开发过程中应避免以相同的配置初始化多个消费者。。 不建议频繁创建和销毁消费者 Apache RocketMQ 的消费者是可以重复利用的底层资源,类似数据库的连接池。因此不需要在每次接收消息时动态创建消费者,且在消费完成后销毁消费者。这样频繁地创建销毁会在服务端产生大量短连接请求,严重影响系统性能。 正确使用示例如下: Consumer c = ConsumerBuilder.build(); for (int i =0;i Consumer c = ConsumerBuilder.build(); Message m= c.receive(); //process message c.shutdown(); } |
今日新闻 |
推荐新闻 |
CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3 |